package org.lds.simple.disruptor.consumer.exception;

import lombok.extern.slf4j.Slf4j;
import org.lds.simple.disruptor.consumer.exception.ConsumeExceptionHandler;

@Slf4j
public class RecordLogConsumeExceptionHandler implements ConsumeExceptionHandler {
    @Override
    public <T> void handleException(T event, long sequence, Throwable e) {
        log.error("消费异常: event={} sequence={}", event, sequence, e);
    }
}
